package com.manlitech.cloud.stream.config.rocketmq;

import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;

/**
 * @author shensg
 * @date 2021/7/29 15:45
 */
@Component
public class RmqConfig {

    @Value("${server.port}")
    public String port;
    /**
     * Name Server 地址，因为是集群部署 所以有多个用 分号 隔开
     */
    @Value("${mq.rocketmq.nameserver}")
    public String NAME_SERVER;
    /**
     * 主题名称 主题一般是服务器设置好 而不能在代码里去新建topic（ 如果没有创建好，生产者往该主题发送消息 会报找不到topic错误）
     */
    @Value("${mq.rocketmq.topic}")
    public String TOPIC;
    /**
     * 生产者组
     */
    @Value("${mq.rocketmq.producergroup}")
    public String PRODUCER_GROUP;
    /**
     * 消费者组
     */
    @Value("${mq.rocketmq.consumergroup}")
    public String CONSUMER_GROUP;

}
